package com.interview.rpc.example;

import com.interview.rpc.server.RpcServer;

/**
 * RPC服务器演示
 * 
 * 启动RPC服务器并注册UserService服务
 */
public class RpcServerDemo {
    
    public static void main(String[] args) throws Exception {
        // 创建RPC服务器，监听8080端口
        // 8080是端口号，客户端需要连接这个端口才能与服务器通信
        RpcServer server = new RpcServer(8080);
        
        // 注册服务
        // 第一个参数是服务接口的全限定名
        // 第二个参数是服务的具体实现类实例
        server.addService(UserService.class.getName(), new UserServiceImpl());
        
        // 启动服务器
        // 这个方法会阻塞，直到服务器关闭
        System.out.println("正在启动RPC服务器...");
        server.start();
    }
}